package com.cyh.Aggregation_Trigger_Task_Interruptted_Handle;

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

/**
 * Created by yanhuche on 3/15/2017.
 */
public class ReporterClient {

    public static void main(String[] args) {
        new ReporterClient().run();
    }

    private void run() {
        ScheduledExecutorService executorService = Executors.newSingleThreadScheduledExecutor();
        executorService.scheduleAtFixedRate(new AggregationTrigger(), 0, 10, TimeUnit.SECONDS);
    }


}
